package com.biubiux2.async.consumer.entity;

import com.biubiux2.handler.MessageProcessor;
import io.netty.buffer.ByteBuf;
import io.netty.channel.Channel;

/**
 * @author Lijinbao
 * @since 8/8/2022 1:34 PM
 */
public class MsgEvent {

    public Channel channel;

    public ByteBuf byteBuf;

    public void consume() {
        channel.writeAndFlush(byteBuf);
    }
}
